package day_14.homework;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author ck
 * @date2021/8/22 22:41
 */
@SuppressWarnings("all")
public class Foodie_1 extends  Thread{
    //创建阻塞队列，记得要定义泛型
    private ArrayBlockingQueue<String> bq;
    //定义一个标记
    private int b = 0;
    //含参数构造方法
    public Foodie_1(ArrayBlockingQueue<String> bq) {
        this.bq = bq;
    }
    //重写Thread中的run方法
    @Override
    public void run() {
        //死循环
        while (true){
            try {
                //take方法将队列中的元素拿出来返回一个String对象
                String take = bq.take();
                System.out.println("吃货将"+take+"拿出来吃掉");
                b++;
                if (b==10){
                    break;
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
